package cn.com.bluemoon.bd.flink.udf;

import org.apache.flink.table.functions.ScalarFunction;

import java.sql.Timestamp;

public class Plus8hour extends ScalarFunction {
    public Timestamp eval(Timestamp s) {
        long newTimeStamp = s.getTime() + 28800000;
        return new Timestamp(newTimeStamp);
    }
}
